#! /bin/bash

nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "iotVehicleNumFromUsecase" --timeKey "statisticsTime" --print "data" > iotVehicleNumFromUsecase_data_new.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "deviceWarning" --timeKey "inputTime" --print "data" > deviceWarning_data_new.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "rscu_msg" --print "data"> rscu_msg_data_new.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "iotTrafficEvent"  --print "data"> iotTrafficEvent_data_new.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "v2x_3d_obstacle" --print "data" > v2x_3d_obstacle_data_new.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "10.251.80.233:9092" --topic "traffic_control_queue_length" --print "data" > traffic_control_queue_length_data_new.log &

nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "iotVehicleNumFromUsecase" --timeKey "statisticsTime" --print "data" > iotVehicleNumFromUsecase_data_old.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "deviceWarning" --timeKey "inputTime" --print "data" > deviceWarning_data_old.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "rscu_msg" --print "data"> rscu_msg_data_old.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "iotTrafficEvent"  --print "data"> iotTrafficEvent_data_old.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "v2x_3d_obstacle" --print "data" > v2x_3d_obstacle_data_old.log &
nohup python3 kafkamsg_sum.py --bootstrap_servers "kafka.cluster.local:8397" --topic "traffic_control_queue_length" --print "data" > traffic_control_queue_length_data_old.log &